package com.doit.day02;

import com.doit.day01.Util;
import org.apache.commons.lang3.RandomUtils;
import redis.clients.jedis.Jedis;

public class Consumer {
    public static void main(String[] args) throws InterruptedException {
        Jedis jedis = Util.getJedis();

        while (true){
            //首先要将生产者队列里面的任务拿出来，放在缓冲区
            jedis.rpoplpush("producer","cache");

            String task = jedis.rpop("cache");

            if (RandomUtils.nextInt(100,200)%3 == 0){
                //假设这个任务失败了，要重新放回到缓冲区
                jedis.lpush("cache",task);
                System.out.println("任务失败了，重新放回到了缓冲区，失败的任务名为："+task);
            }else {
                System.out.println("任务成功，耿工的任务名为："+task);
            }
            Thread.sleep(RandomUtils.nextInt(400,500));
        }
    }
}
